dc52e318137e6e80391578206f8537b9839b499f,tests/perf/org/jgroups/tests/perf/Test.java,Test,handleData,#Object#number#,337

Before Change


            if(all_received)
                return;
            if(start == 0) {
                start=System.currentTimeMillis();
            }

            num_msgs_received++;

After Change


            if(all_received)
                return;
            if(start == 0) {
                start=last_interval=System.currentTimeMillis();
            }

            num_msgs_received++;
            num_bytes_received+=num_bytes;

            if(num_msgs_received >= num_msgs_expected) {
                if(stop == 0) {
                    stop=System.currentTimeMillis();
                }
                all_received=true;
            }

            if(num_msgs_received % log_interval == 0) {
                long curr=System.currentTimeMillis();
                long diff=curr - last_interval;
                last_interval=curr;
                double msgs_sec=log_interval / (diff / 1000.0);
                System.out.println(new StringBuilder("-- received ").append(num_msgs_received).append(" messages")